package com.intretech.tj.mqtt.trigger;

import com.intretech.tj.global.parent.TriggerParent;
import io.vertx.mutiny.mqtt.messages.MqttPublishMessage;
import jakarta.enterprise.context.ApplicationScoped;

/**
 * 主题消息触发器<br/>
 * key:主题<br/>
 * type:{@link IDAndMessage} 匹配该主题的消息与消息发布者
 */
@ApplicationScoped
public class TopicMessageTrigger extends TriggerParent<TopicMessageTrigger.IDAndMessage> {

    public record IDAndMessage(String clientID, MqttPublishMessage message) {
    }
}
